package com.boot.streamreceive;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * 测试1 ：消息驱动的微服务（入门）
 * 开启 rabbitMQ ，访问 http://localhost:15672/#/， 启动 stream-hello application
 * 在 Connections 界面 会发现 一个连接，成功
 * 在 Queues 界面， 进入 input.anonymous.Y8VsFILmSC27eS5StsXp6A 队列的管理页面，在 Publish message 中，尝试发送信息，成功
 *
 * 测试2： 消息驱动的微服务（入门）
 * 运行测试用例
 * Received: produce a message ：http://www.github.com
 *
 *
 *
 * StreamReceive   SinkSender   消息生产者  每两秒发送一条信息
 * StreamSend      SinkReceiver 消息消费者  接收消息
 *
 * 测试3： 消息驱动的微服务（消费组）
 * 开启 stream-receive（多个）、stream-send
 *
 * 测试4： 消息驱动的微服务（消息分区）
 * 开启 stream-receive（多个）、stream-send
 */
@SpringBootApplication
public class StreamReceiveApplication {

	public static void main(String[] args) {
		SpringApplication.run(StreamReceiveApplication.class, args);
	}
}
